package com.example.client.message;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.SubscribableChannel;

public interface StreamIO {

    String IN = "topic-in";
    String OUT = "topic-out";
    @Input(IN)
    SubscribableChannel in();

    @Output(OUT)
    MessageChannel out();

}
